package com.flink.ttest.cofig;

import org.apache.flink.api.java.functions.KeySelector;

/**
 * @author: LCG
 * @date: 2022-06-28 13:46:46
 * @description:
 **/
public class MyOrderKeySelecter implements KeySelector<Order,String> {
    @Override
    public String getKey(Order order) throws Exception {
        return order.getUserId();
    }
}
